package tcplib

import (
	"MqttCloudProtocolServer/ProtocolServer/mqttlib"
	"MqttCloudProtocolServer/publiclib/datamodel"
	"MqttCloudProtocolServer/publiclib/datamodel/dborm"
	"net"
)

//TCPDirectServer TCP收发服务器
type TCPDirectServer struct {
	mqttlib.OperatorBase
	//tcp          *datamodel.TCPClient
	dbtcp        *dborm.Manageserver
	listener     net.Listener
	receiver     func(key string, buffer []uint8)
	frameBuffer  chan frameObject
	currentFrame *frameObject
	isRunning    bool
	rwLocker     datamodel.WaitLocker
	bufferLen    int
	timeout      int
}
